package com.moxiao.yfjh.module.system.mq.kafka;


import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class KafkaConsumer {

//    @KafkaListener(topics = {KAFKA_BLIND_MEMBER_USER_KEY})
//    public void listen(ConsumerRecord<?, ?> record) {
//        Optional.ofNullable(record.value())
//                .ifPresent(
//                        message -> {/**/
//                            log.info("【+++++++++++++++++ record = {} 】", record);
//                            log.info("【消费者接收会员用户注册message : {}】", message);
//                            try {
////                                Message msg = (Message) message;
//                                log.info("【输出消费者消息 : {}】", message);
//                                cn.hutool.json.JSONObject jsonObject = new cn.hutool.json.JSONObject(message);
//                                System.out.println("====== 消费者接收会员用户注册message ======" + jsonObject.get("mobile"));
//                                System.out.println("==== 消费者接收会员用户注册message =======" + jsonObject.get("accessToken"));
//                                System.out.println("===== 消费者接收会员用户注册message =====" + jsonObject.get("userId"));
//                                System.out.println("===== 消费者接收会员用户注册message =====" + jsonObject.get("pesence"));
//                                System.out.println("===== 消费者接收会员用户注册message =====" + jsonObject.get("createTime"));
////                                JSONObject jsonObject2 = new JSONObject(message.toString());
////                                // 处理消费的消息
////                                JSONArray jsonArray = new JSONArray();
////                                jsonArray.add(message);
////                                String prettyJson = null;
////                                prettyJson = objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(json);
//                                System.out.println("=========================== 消费者接收会员用户注册message ===========================" + message);
//                            } catch (Exception e) {
//                                e.printStackTrace();
//                            }
//                        });
//    }

}
